-
Notifications
You must be signed in to change notification settings - Fork 36
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Baremetal / Add stork consul scenario #572
Conversation
09c96ed
to
e2cff3e
Compare
service-discovery/stork-consul/src/main/java/io/quarkus/ts/stork/PongReplicaResource.java
Outdated
Show resolved
Hide resolved
service-discovery/stork-consul/src/test/java/io/quarkus/ts/stork/StorkServiceDiscoveryIT.java
Outdated
Show resolved
Hide resolved
service-discovery/stork-consul/src/test/java/io/quarkus/ts/stork/StorkServiceDiscoveryIT.java
Outdated
Show resolved
Hide resolved
service-discovery/stork-consul/src/test/java/io/quarkus/ts/stork/StorkServiceDiscoveryIT.java
Outdated
Show resolved
Hide resolved
service-discovery/stork-consul/src/test/java/io/quarkus/ts/stork/StorkServiceDiscoveryIT.java
Outdated
Show resolved
Hide resolved
service-discovery/stork-consul/src/test/java/io/quarkus/ts/stork/StorkServiceDiscoveryIT.java
Outdated
Show resolved
Hide resolved
service-discovery/stork-consul/src/test/java/io/quarkus/ts/stork/StorkServiceDiscoveryIT.java
Outdated
Show resolved
Hide resolved
cd59788
to
e0bfe65
Compare
aff2e78
to
0efc8f3
Compare
public void init(@Observes StartupEvent ev, Vertx vertx) { | ||
if (serviceDiscoveryType.equalsIgnoreCase("consul")) { | ||
ConsulClient client = ConsulClient.create(vertx, | ||
new ConsulClientOptions().setHost(host).setPort(Integer.parseInt(port))); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
this.port
, if you don't mind. Also, can't we have integer ConfigProperties?
} catch (IOException e) { | ||
fail("no free port available."); | ||
} | ||
return String.valueOf(-1); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Will Quarkus handle such port number properly?
service-discovery/stork/src/test/java/io/quarkus/ts/stork/StorkServiceDiscoveryIT.java
Outdated
Show resolved
Hide resolved
public void init(@Observes StartupEvent ev, Vertx vertx) { | ||
if (serviceDiscoveryType.equalsIgnoreCase("consul")) { | ||
ConsulClient client = ConsulClient.create(vertx, | ||
new ConsulClientOptions().setHost(host).setPort(Integer.parseInt(port))); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Here, and everywhere in Resources:
new ConsulClientOptions().setHost(host).setPort(Integer.parseInt(port))); | |
new ConsulClientOptions().setHost(host).setPort(Integer.parseInt(this.port))); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Let's keep it as it's other modules. there is no a team agreement about that
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Currently, we are following this principle: https://checkstyle.sourceforge.io/config_coding.html#RequireThis
But is true that is not added to checkstyle template
<module name="RequireThis">
<property name="validateOnlyOverlapping" value="true"/>
</module>
- default service discovery - default load balncer
Description
Verifies Stork-consul integration in order to provide service discovering and round-robin load balancing between services
StorkServiceDiscoveryIT
scenario deploys four services:pung
andpong
(Pong and PongReplica) services. The servicediscovery will be done by Stork, and the request dispatching between "pong" services is going to be done by Stork load balancer.
Test Plan coverage
Reported issues:
Missing stork quarkus properties: quarkusio/quarkus#24341
Service discovery expiration time: quarkusio/quarkus#24343